现在 Server/Client->send
在缓存区已满的情况下,会直接返回false
,需要借助onBufferFull
和onBufferEmpty
这样复杂的事件通知机制才能实现任务的暂停和恢复。
在实现需要大量发送的场景下,现有机制虽然可以实现,但非常复杂。
现在基于协程可以实现一种机制,直接在当前协程内yield
,等待数据发送完成,缓存区清空时,自动resume
当前协程,继续send
数据。
Server/Client->send
返回false
并且错误码为SW_ERROR_OUTPUT_BUFFER_OVERFLOW
时,不返回false
到php
层,而是yield
挂起当前协程Server/Client
监听onBufferEmpty
事件,在该事件触发后,缓存区内的数据已被发送完毕,这时resume
对应的协程- 协程恢复后,继续调用
Server/Client->send
向缓存区内写入数据,这时因为缓存区已空,发送必然是成功的
for ($i = 0; $i < 100; $i++)
{
//在缓存区塞满时会直接返回`false`
$server->send($fd, $data_2m);
}
for ($i = 0; $i < 100; $i++)
{
//在缓存区塞满时会 yield 当前协程,发送完成后 resume 继续向下执行
$server->send($fd, $data_2m);
}
此项特性会改变底层的默认行为,因此需要额外的一个参数来开启。
$serv->set([
'send_yield' => true,
]);
Swoole\Server::send
Swoole\Http\Response::write
Swoole\WebSocket\Server::push
Swoole\Coroutine\Client::send
Swoole\Coroutine\Http\Client::push